from celery import Celery


def asd(mobile, sms_code):
    app = Celery(
        broker='amqp://guest@localhost//',  # 消息队列的url
        # backend='amqp://guest@localhost//',  # 将调用的结果存储到MQ中
        backend='redis://localhost:6379/9'  # 将调用的结果存储到Redis中
    )

    # send_task在发送的时候是不会检查tasks3.add函数是否存在的，即使为空也会发送成功，所以celery执行是可能找不到该函数报错；
    ret = app.send_task('work.send_sms_code', args=[mobile, sms_code])

    print(ret)

    # print(ret.get(timeout=2))
